package com.zhouyu.config.listener;

import com.zhouyu.dto.CommonPayOutDto;

import org.springframework.batch.core.ItemWriteListener;

import java.util.List;

import lombok.extern.log4j.Log4j2;

/**
 * @Description:写出到数据源失败监听处理
 */
@Log4j2
public class ItemWriteErrorListener implements ItemWriteListener<CommonPayOutDto> {

  @Override
  public void beforeWrite(List list) {

  }

  @Override
  public void afterWrite(List list) {

  }

  /**
   * 失败回传的是一个step设置的chunk数据集，所以是list
   * @param e
   * @param list
   */
  @Override
  public void onWriteError(Exception e, List<? extends CommonPayOutDto> list) {
      log.error("读取失败,原因是:{}",e.getMessage());
      list.forEach(common->{
        log.error("读取失败的数据:{}",common);
      });
  }
}
